Accumulator Flow
This Flow will have behaviour very similar to SharedFlow, but there are several differences:
All unhandled by FlowCollector data will not be removed from AccumulatorFlow and will be sent to new FlowCollectors until anybody will handle it
Here there are an activeData where data T will be stored until somebody will handle it
Constructors
Functions
Extensions
Creates AccumulatorFlow using this as base Flow
Creates AccumulatorFlow using this as base Flow
Creates AccumulatorFlow using this as base Flow
Shortcut for chain if Flow.onEach and Flow.launchIn
Shortcut for chain if Flow.onEach and Flow.launchIn
Use subscribe, but all blocks will be called inside of safely function. Use onException to set up your reaction for Throwables
Use subscribe, but all blocks will be called inside of safely function. Use onException to set up your reaction for Throwables
Use subscribe, but all blocks will be called inside of safely function. Use onException to set up your reaction for Throwables
Use subscribeSafelyWithoutExceptions, but all exceptions inside of safely will be skipped
Use subscribeSafelyWithoutExceptions, but all exceptions inside of safely will be skipped
Use subscribeSafelyWithoutExceptions, but all exceptions inside of safely will be skipped
Use subscribeSafelyWithoutExceptions, but all exceptions will be passed to defaultSafelyExceptionHandler
Use subscribeSafelyWithoutExceptions, but all exceptions will be passed to defaultSafelyExceptionHandler
Use subscribeSafelyWithoutExceptions, but all exceptions will be passed to defaultSafelyExceptionHandler